package com.线程池.自定义线程池;

import com.线程池.MyRunnable;

import java.util.concurrent.*;

public class MyThreadPoolDemp {


    public static void main(String[] args) {
        ThreadPoolExecutor pool1= new ThreadPoolExecutor(
                3,//核心线程数量
                6,//最大线程数，不能小于0，>=核心线程数量
                60,//最大存活时间
                TimeUnit.SECONDS,//时间单位
                new LinkedBlockingQueue<>(3),//任务队列
                Executors.defaultThreadFactory(),//获取线程工厂
                new ThreadPoolExecutor.AbortPolicy()//任务的拒绝策略
        );
        pool1.submit(new MyRunnable());
        pool1.shutdown();


    }
}
